package com.atguigu.gulimall.zzmycanal.config;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.xpand.starter.canal.annotation.CanalEventListener;
import com.xpand.starter.canal.annotation.ListenPoint;

@CanalEventListener
public class OmsListening {

    @ListenPoint(schema = "gulimall_oms", table = {"oms_order"})
    public void oms_order(CanalEntry.RowData rowData) {
        System.err.println("oms_order");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"oms_order_item"})
    public void oms_order_item(CanalEntry.RowData rowData) {
        System.err.println("oms_order_item");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"oms_order_operator_history"})
    public void oms_order_operator_history(CanalEntry.RowData rowData) {
        System.err.println("oms_order_operator_history");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"oms_order_return_apply"})
    public void oms_order_return_apply(CanalEntry.RowData rowData) {
        System.err.println("oms_order_return_apply");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"oms_order_settings"})
    public void oms_order_settings(CanalEntry.RowData rowData) {
        System.err.println("oms_order_settings");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"oms_payment_info"})
    public void oms_payment_info(CanalEntry.RowData rowData) {
        System.err.println("oms_payment_info");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"oms_refund_info"})
    public void oms_refund_info(CanalEntry.RowData rowData) {
        System.err.println("oms_refund_info");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"mq_message"})
    public void mq_message(CanalEntry.RowData rowData) {
        System.err.println("mq_message");
        ShowObj.showData(rowData);
    }



}
